4be4ed0b280d92aacf1a30b88008258884a14301,src/main/java/org/springframework/data/redis/connection/lettuce/LettuceConnection.java,LettuceConnection,pfCount,#number[]#,4400

Before Change


		Assert.noNullElements(keys, "Keys for PFCOUNT must not contain 'null'.");
		try {
			if (isPipelined()) {
				if (keys.length == 1) {
					pipeline(new LettuceResult(getAsyncConnection().pfcount(keys[0])));
				} else {
					pipeline(new LettuceResult(getAsyncConnection().pfcount(keys[0], LettuceConverters.subarray(keys, 1))));
				}
				return null;
			}
			if (isQueueing()) {
				if (keys.length == 1) {
					transaction(new LettuceTxResult(getConnection().pfcount(keys[0])));
				} else {
					transaction(new LettuceTxResult(getConnection().pfcount(keys[0], LettuceConverters.subarray(keys, 1))));
				}

				return null;
			}

			if (keys.length == 1) {
				return getConnection().pfcount(keys[0]);
			}

			return getConnection().pfcount(keys[0], LettuceConverters.subarray(keys, 1));
		} catch (Exception ex) {
			throw convertLettuceAccessException(ex);
		}

After Change


	 * @see org.springframework.data.redis.connection.HyperLogLogCommands#pfCount(byte[][])
	 */
	@Override
	public Long pfCount(byte[]... keys) {

		Assert.notEmpty(keys, "PFCOUNT requires at least one non 'null' key.");
		Assert.noNullElements(keys, "Keys for PFCOUNT must not contain 'null'.");
		try {
			if (isPipelined()) {
				RedisHLLAsyncCommands<byte[], byte[]> asyncConnection = getAsyncConnection();
				pipeline(new LettuceResult(asyncConnection.pfcount(keys)));
				return null;
			}

			if (isQueueing()) {
				RedisHLLAsyncCommands<byte[], byte[]> asyncConnection = getAsyncConnection();
				transaction(new LettuceResult(asyncConnection.pfcount(keys)));
				return null;
			}

			RedisHLLCommands<byte[], byte[]> connection = getConnection();
			return connection.pfcount(keys);
		} catch (Exception ex) {
			throw convertLettuceAccessException(ex);